/**
 * 
 */
package com.ynet.middleground.riskmanage.job;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import com.ifp.framework.ClusterJob;
import com.ynet.core.log.IfpLogger;
import com.ynet.middleground.riskmanage.model.DaGangModel;

/**
 * 获取大港货种信息
 * @author songyf
 *
 */
@Component
public class DgMasterGoodsTypeJob  extends ClusterJob {
    @Autowired
    private DaGangModel daGangModel;
    
    /**
     * 每日凌晨10分执行job
     * @throws Exception
     */
    
    // 每一分钟跑一次 测试的时候用
    //@Scheduled(cron = "0/59 * * * * ? ")
    // 每天1点启动
    @Scheduled(cron = "0 0 1 * * ? ")
    public void test() throws Exception {
        // 是否领导者
        if(!isLeader()){
            IfpLogger.info("job", "程序不执行");
            return;
        }

        // 同步货种信息
        doSyncMasterGoodsType();
    }

    /**
     * 同步货种信息
     */
    private void doSyncMasterGoodsType() {

        IfpLogger.info("job", "执行同步货种信息更新开始");
        daGangModel.getMasterGoodsType();
        IfpLogger.info("job", "执行同步货种信息更新结束");

    }

}
